package com.nxy.test.rxjava;

import org.reactivestreams.Subscriber;
import org.reactivestreams.Subscription;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * Created by snailnan on 2017/11/27.
 */
public class MySubscriber implements Subscriber {
    private static final Logger logger = LoggerFactory.getLogger(MySubscriber.class);
    @Override
    public void onSubscribe(Subscription s) {
        logger.info("onSubscribe");
    }

    @Override
    public void onNext(Object o) {
        logger.info("onNext");
    }

    @Override
    public void onError(Throwable t) {

    }

    @Override
    public void onComplete() {
        logger.info("onComplete");
    }
}
